package com.star.common.mq.config;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * MQ配置
 *
 * @author Jensen
 * @公众号 架构师修行录
 */
@Data
@ConfigurationProperties(prefix = "star.mq")
public class BaseMQProperties {

    private Kafka kafka;

    @Data
    @AllArgsConstructor
    @NoArgsConstructor
    public static class Kafka {
        /**
         * N小时内重复消息则跳过
         */
        private Integer skipHours = 10;
    }
}
